package org.mxp.demo9.maxlength;

import com.rabbitmq.client.Channel;
import org.mxp.utils.RabbitMQUtils;

public class ReceiveObj2 {
    public static void main(String[] args) throws Exception {
        /*
            这里并没有声明路由、绑定路由，这是因为那些东西都是全局，执行一次即可，我们在消费者1里面意见声明绑定好了路由，这里只管用就行了
            但是要先执行消费者1，或者是将消费者1里面死信队列相关的路由声明绑定给搬到消费者2里面才行，不然会报错
         */
        // 死信队列的名称
        String DEAD_QUEUE = "dead_queue";
        // 获取信道
        Channel channel = RabbitMQUtils.getChannel();
        // 死信队列接受消息
        channel.basicConsume(DEAD_QUEUE, true, (consumerTag, message) -> {
            System.out.println(DEAD_QUEUE + "接受到消息：" + new String(message.getBody()));
        }, (consumerTag) -> {});
    }
}
